<?php 
header("Content-type:text/html;charset=utf-8");
//数据库连接
function connect($host=DB_HOST,$user=DB_USER,$password=DB_PASSWORD,$database=DB_DATABASE){
	$link=@mysqli_connect($host, $user, $password, $database);

	if (mysqli_connect_errno()) {
		exit(mysqli_connect_error());
	}

	mysqli_set_charset($link , 'utf-8');

	return $link;

}


//执行一条sql语句，返回结果集对象或布尔值
function execute($link,$query){
		$result = mysqli_query($link,$query);

		if(mysqli_errno($link)){
			exit(mysqli_error($link));
		}
		
		return  $result;

}
//使用案例：
/*$link = connect();
$query = 'select * from hbw_father_module';
$result=execute($link,$query);
var_dump(mysqli_fetch_assoc($result));*/





//执行一条sql语句，只返回布尔值
function execute_bool($link , $query){
	$bool = mysqli_real_query($link , $query);

	if(mysqli_errno($link)){
			exit(mysqli_error($link));
		}

	return $bool;

}

//一次执行多条sql语句
function execute_multi($link,$arr_sqls,&$error){
	$sqls=implode(';',$arr_sqls).';';
	if(mysqli_multi_query($link,$sqls)){
		$data=array();
		$i=0;//计数
		do {
			if($result=mysqli_store_result($link)){
				$data[$i]=mysqli_fetch_all($result);
				mysqli_free_result($result);
			}else{
				$data[$i]=null;
			}
			$i++;
			if(!mysqli_more_results($link)) break;
		}while (mysqli_next_result($link));
		if($i==count($arr_sqls)){
			return $data;
		}else{
			$error="sql语句执行失败：<br />&nbsp;数组下标为{$i}的语句:{$arr_sqls[$i]}执行错误<br />&nbsp;错误原因：".mysqli_error($link);
			return false;
		}
	}else{
		$error='执行失败！请检查首条语句是否正确！<br />可能的错误原因：'.mysqli_error($link);
		return false;
	}
}

//使用案例：
/*$arr_sqls= array(
		'select * from hbw_father_module',
		'select * from hbw_father_module',
		'select * from hbw_father_module'

);
var_dump(execute_multi($link,$arr_sqls,$error));
echo $error;*/




//获取记录数 mysql_num_rows()
function num($link,$sql_count){
	$result=execute($link,$sql_count);
	$count=mysqli_fetch_row($result);
	return $count[0];
}


//数据入库之前进行转义，确保数据能够顺利入库
function escape($link,$data){
	if(is_string($data)){
		return mysqli_real_escape_string($link,$data);
	}
	if(is_array($data)){
		foreach ($data as $key => $val) {
			$data[$key]=escape($link,$val);
		}
	}

	return $data;




}

//关闭与数据库的连接 
function close($link){
	mysqli_close($link);
}



?>